Node / meshtastic / Meshtastic-Android / files / core / data / src / commonMain / kotlin / org / meshtastic / core / data / repository / MeshLogRepositoryImpl.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.repository

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787kotlinx.coroutines.flow.conflate

Tff7b72import T7ee787kotlinx.coroutines.flow.distinctUntilChanged

Tff7b72import T7ee787kotlinx.coroutines.flow.firstOrNull

Tff7b72import T7ee787kotlinx.coroutines.flow.flatMapLatest

Tff7b72import T7ee787kotlinx.coroutines.flow.flowOn

Tff7b72import T7ee787kotlinx.coroutines.flow.map

Tff7b72import T7ee787kotlinx.coroutines.flow.mapLatest

Tff7b72import T7ee787kotlinx.coroutines.withContext

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis

Tff7b72import T7ee787org.meshtastic.core.data.datasource.NodeInfoReadDataSource

Tff7b72import T7ee787org.meshtastic.core.database.DatabaseProvider

Tff7b72import T7ee787org.meshtastic.core.database.entity.asEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.asExternalModel

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.model.MeshLog

Tff7b72import T7ee787org.meshtastic.core.model.util.TELEMETRY_CHANNEL_COUNT

Tff7b72import T7ee787org.meshtastic.core.model.util.adcVoltage

Tff7b72import T7ee787org.meshtastic.core.model.util.oneWireTemperature

Tff7b72import T7ee787org.meshtastic.core.model.util.withAdcVoltage

Tff7b72import T7ee787org.meshtastic.core.model.util.withLegacyOneWireTemperatures

Tff7b72import T7ee787org.meshtastic.core.model.util.withOneWireTemperature

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogPrefs

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRepository

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRepository.Companion.DEFAULT_MAX_LOGS

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRetention

Tff7b72import T7ee787org.meshtastic.proto.EnvironmentMetrics

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.MyNodeInfo

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.proto.Telemetry

T8b949e/**

* Repository implementation for managing and retrieving logs from the local database.

*

* This repository provides methods for inserting, deleting, and querying logs, including specialized methods for

* telemetry and traceroute data.

*/

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)

Tf0883e@Single

Tff7b72open Tff7b72class T56d364MeshLogRepositoryImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3dbManagerTb4b4b4: Te6edf3DatabaseProviderTb4b4b4,

Tff7b72private Tff7b72val Te6edf3dispatchersTb4b4b4: Te6edf3CoroutineDispatchersTb4b4b4,

Tff7b72private Tff7b72val Te6edf3meshLogPrefsTb4b4b4: Te6edf3MeshLogPrefsTb4b4b4,

Tff7b72private Tff7b72val Te6edf3nodeInfoReadDataSourceTb4b4b4: Te6edf3NodeInfoReadDataSourceTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3MeshLogRepository Tb4b4b4{

T8b949e/** Retrieves all [MeshLog]s in the database, up to [maxItem]. */

Tff7b72override Tff7b72fun Td2a8ffgetAllLogsTb4b4b4(Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllLogsTb4b4b4(Te6edf3maxItemTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e/** Retrieves all [MeshLog]s in the database in the order they were received. */

Tff7b72override Tff7b72fun Td2a8ffgetAllLogsInReceiveOrderTb4b4b4(Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllLogsInReceiveOrderTb4b4b4(Te6edf3maxItemTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e/** Retrieves all [MeshLog]s in the database without any limit. */

Tff7b72override Tff7b72fun Td2a8ffgetAllLogsUnboundedTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72> Tff7b72= Te6edf3getAllLogsTb4b4b4(Tffa657IntTb4b4b4.Te6edf3MAX_VALUETb4b4b4)

T8b949e/** Retrieves all [MeshLog]s associated with a specific [nodeNum] and [portNum]. */

Tff7b72override Tff7b72fun Td2a8ffgetLogsFromTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getLogsFromTb4b4b4(Te6edf3nodeNumTb4b4b4, Te6edf3portNumTb4b4b4, Te6edf3DEFAULT_MAX_LOGSTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e/** Retrieves all [MeshLog]s containing [MeshPacket]s for a specific [nodeNum]. */

Tff7b72override Tff7b72fun Td2a8ffgetMeshPacketsFromTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshPacketTff7b72>Tff7b72> Tff7b72=

Te6edf3getLogsFromTb4b4b4(Te6edf3nodeNumTb4b4b4, Te6edf3portNumTb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3mapNotNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3fromRadioTb4b4b4.Te6edf3packet Tb4b4b4} Tb4b4b4}Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e/** Retrieves telemetry history for a specific node, automatically handling local node redirection. */

Tff7b72override Tff7b72fun Td2a8ffgetTelemetryFromTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3TelemetryTff7b72>Tff7b72> Tff7b72= Te6edf3effectiveLogIdTb4b4b4(Te6edf3nodeNumTb4b4b4)

Tb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3logId Tff7b72-Tff7b72>

Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{

Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getLogsFromTb4b4b4(Te6edf3logIdTb4b4b4, Te6edf3PortNumTb4b4b4.Te6edf3TELEMETRY_APPTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3DEFAULT_MAX_LOGSTb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3mapLatest Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4.Te6edf3mapNotNullTb4b4b4(Tff7b72::Te6edf3parseTelemetryLogTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e/**

* Retrieves all outgoing request logs for a specific [targetNodeNum] and [portNum].

*

* A request log is defined as an outgoing packet (`fromNum = 0`) where `want_response` is true.

*/

Tff7b72override Tff7b72fun Td2a8ffgetRequestLogsTb4b4b4(Te6edf3targetNodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Te6edf3PortNumTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getLogsFromTb4b4b4(Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCALTb4b4b4, Te6edf3portNumTb4b4b4.Te6edf3valueTb4b4b4, Te6edf3DEFAULT_MAX_LOGSTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72>

Te6edf3list

Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3filter Tb4b4b4{ Te6edf3log Tff7b72-Tff7b72>

Tff7b72val Te6edf3packet Tff7b72= Te6edf3logTb4b4b4.Te6edf3fromRadioTb4b4b4.Te6edf3packet Tff7b72?: Tff7b72returnTf0883e@filter Tff7b72false

Te6edf3logTb4b4b4.Te6edf3fromNum Tff7b72=Tff7b72= Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72&Tff7b72&

Te6edf3packetTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3targetNodeNum Tff7b72&Tff7b72&

Te6edf3packetTb4b4b4.Te6edf3decodedTff7b72?.Te6edf3want_response Tff7b72=Tff7b72= Tff7b72true

Tb4b4b4}

Tb4b4b4}

Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3conflateTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffparseTelemetryLogTb4b4b4(Te6edf3logTb4b4b4: Te6edf3MeshLogTb4b4b4)Tb4b4b4: Te6edf3Telemetry? Tff7b72= Te6edf3runCatching Tb4b4b4{

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3logTb4b4b4.Te6edf3fromRadioTb4b4b4.Te6edf3packetTff7b72?.Te6edf3decoded Tff7b72?: Tff7b72returnTf0883e@runCatching Tff7b72null

T8b949e// Requests for telemetry (want_response = true) should not be logged as data points.

Tff7b72if Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3want_response Tff7b72=Tff7b72= Tff7b72trueTb4b4b4) Tff7b72returnTf0883e@runCatching Tff7b72null

Tff7b72val Te6edf3telemetry Tff7b72= Te6edf3TelemetryTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3payloadTb4b4b4)

Te6edf3telemetryTb4b4b4.Te6edf3copyTb4b4b4(

Te6edf3time Tff7b72= Tb4b4b4(Te6edf3logTb4b4b4.Te6edf3received_date Tff7b72/ Te6edf3MILLIS_PER_SECTb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3environment_metrics Tff7b72= Te6edf3telemetryTb4b4b4.Te6edf3environment_metricsTff7b72?.Te6edf3withSentinelsForAbsentReadingsTb4b4b4(Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3getOrNullTb4b4b4(Tb4b4b4)

T8b949e/** Returns a flow that maps a [nodeNum] to [MeshLog.NODE_NUM_LOCAL] if it is the locally connected node. */

Tff7b72private Tff7b72fun Td2a8ffeffectiveLogIdTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3nodeInfoReadDataSource

Tb4b4b4.Te6edf3myNodeInfoFlowTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3info Tff7b72-Tff7b72> Tff7b72if Tb4b4b4(Te6edf3nodeNum Tff7b72=Tff7b72= Te6edf3infoTff7b72?.Te6edf3myNodeNumTb4b4b4) Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72else Te6edf3nodeNum Tb4b4b4}

Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)

T8b949e/** Returns the cached [MyNodeInfo] from the system logs. */

Tff7b72override Tff7b72fun Td2a8ffgetMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3MyNodeInfo?Tff7b72> Tff7b72= Te6edf3dbManager

Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getLogsFromTb4b4b4(Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCALTb4b4b4, T79c0ff0Tb4b4b4, Te6edf3DEFAULT_MAX_LOGSTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3mapLatest Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4.Te6edf3firstOrNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeInfo Tff7b72!Tff7b72= Tff7b72null Tb4b4b4}Tff7b72?.Te6edf3myNodeInfo Tb4b4b4}

Tb4b4b4.Te6edf3flowOnTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4)

T8b949e// Writes go through withDb so they register with the cross-transport merge drain barrier (see DatabaseProvider).

T8b949e/** Persists a new log entry to the database if logging is enabled in preferences. */

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertTb4b4b4(Te6edf3logTb4b4b4: Te6edf3MeshLogTb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3meshLogPrefsTb4b4b4.Te6edf3loggingEnabledTb4b4b4.Te6edf3valueTb4b4b4) Tff7b72returnTf0883e@withContext

Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3logTb4b4b4.Te6edf3asEntityTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tffa657Unit

Tb4b4b4}

T8b949e/** Clears all logs from the database. */

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteAllTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteAllTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4}

T8b949e/** Deletes a specific log entry by its [uuid]. */

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogTb4b4b4(Te6edf3uuidTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteLogTb4b4b4(Te6edf3uuidTb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4}

T8b949e/** Deletes all logs associated with a specific [nodeNum] and [portNum]. */

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogsTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3nodeInfoReadDataSourceTb4b4b4.Te6edf3myNodeInfoFlowTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3firstOrNullTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3myNodeNum

Tff7b72val Te6edf3logId Tff7b72= Tff7b72if Tb4b4b4(Te6edf3nodeNum Tff7b72=Tff7b72= Te6edf3myNodeNumTb4b4b4) Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72else Te6edf3nodeNum

Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteLogsTb4b4b4(Te6edf3logIdTb4b4b4, Te6edf3portNumTb4b4b4) Tb4b4b4}

Tffa657Unit

Tb4b4b4}

T8b949e/**

* Deletes only local stats telemetry logs for [nodeNum], preserving other telemetry types. The bounded keyset scan

* and atomic deletion remain under one manager-tracked database lease, while protobuf parsing runs on the compute

* dispatcher.

*/

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteLocalStatsLogsTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3nodeInfoReadDataSourceTb4b4b4.Te6edf3myNodeInfoFlowTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3firstOrNullTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3myNodeNum

Tff7b72val Te6edf3logId Tff7b72= Tff7b72if Tb4b4b4(Te6edf3nodeNum Tff7b72=Tff7b72= Te6edf3myNodeNumTb4b4b4) Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72else Te6edf3nodeNum

Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Te6edf3selectedDb Tff7b72-Tff7b72>

Tff7b72val Te6edf3dao Tff7b72= Te6edf3selectedDbTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3uuidsToDelete Tff7b72= Te6edf3mutableListOfTff7b72<Tffa657StringTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72var Te6edf3beforeReceivedDateTb4b4b4: Tffa657Long? Tff7b72= Tff7b72null

Tff7b72var Te6edf3beforeUuidTb4b4b4: Tffa657String? Tff7b72= Tff7b72null

Tff7b72do Tb4b4b4{

Tff7b72val Te6edf3page Tff7b72=

Te6edf3daoTb4b4b4.Te6edf3getLogsSnapshotPageTb4b4b4(

Te6edf3fromNum Tff7b72= Te6edf3logIdTb4b4b4,

Te6edf3portNum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TELEMETRY_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3beforeReceivedDate Tff7b72= Te6edf3beforeReceivedDateTb4b4b4,

Te6edf3beforeUuid Tff7b72= Te6edf3beforeUuidTb4b4b4,

Te6edf3pageSize Tff7b72= Te6edf3TELEMETRY_SNAPSHOT_PAGE_SIZETb4b4b4,

Tb4b4b4)

Te6edf3uuidsToDelete Tff7b72+Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3defaultTb4b4b4) Tb4b4b4{

Te6edf3page

Tb4b4b4.Te6edf3asSequenceTb4b4b4(Tb4b4b4)

Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3asExternalModelTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3filter Tb4b4b4{ Te6edf3parseTelemetryLogTb4b4b4(Tffa657itTb4b4b4)Tff7b72?.Te6edf3local_stats Tff7b72!Tff7b72= Tff7b72null Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3uuid Tb4b4b4}

Tb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tb4b4b4}

Te6edf3pageTb4b4b4.Te6edf3lastOrNullTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3last Tff7b72-Tff7b72>

Te6edf3beforeReceivedDate Tff7b72= Te6edf3lastTb4b4b4.Te6edf3received_date

Te6edf3beforeUuid Tff7b72= Te6edf3lastTb4b4b4.Te6edf3uuid

Tb4b4b4}

Tb4b4b4} Tff7b72while Tb4b4b4(Te6edf3pageTb4b4b4.Te6edf3size Tff7b72=Tff7b72= Te6edf3TELEMETRY_SNAPSHOT_PAGE_SIZETb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3uuidsToDeleteTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3daoTb4b4b4.Te6edf3deleteLogsByUuidAtomicTb4b4b4(Te6edf3uuidsToDeleteTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tffa657Unit

Tb4b4b4}

T8b949e/**

* Prunes the log database based on the configured [retentionDays]. The sentinel values are resolved by

* [MeshLogRetention], so "never delete" is a no-op and "1 hour" trims to the last hour rather than scaling the

* sentinel by days.

*/

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogsOlderThanTb4b4b4(Te6edf3retentionDaysTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3window Tff7b72= Te6edf3MeshLogRetentionTb4b4b4.Te6edf3windowOrNullTb4b4b4(Te6edf3retentionDaysTb4b4b4) Tff7b72?: Tff7b72returnTf0883e@withContext

Tff7b72val Te6edf3cutoffTime Tff7b72= Te6edf3nowMillis Tff7b72- Te6edf3windowTb4b4b4.Te6edf3inWholeMilliseconds

Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3meshLogDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteOlderThanTb4b4b4(Te6edf3cutoffTimeTb4b4b4) Tb4b4b4}

Tffa657Unit

Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3MILLIS_PER_SEC Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0L

Tff7b72private Tff7b72const Tff7b72val Te6edf3TELEMETRY_SNAPSHOT_PAGE_SIZE Tff7b72= T79c0ff5T79c0ff1T79c0ff2

Tb4b4b4}

Tb4b4b4}

T8b949e/**

* Replaces absent optional readings with the sentinel the graphing layer filters on, so every field reaches the charts

* through one representation.

*

* Only presence is normalized: a reported `0` is a real reading on every field here and is preserved. Historical logs

* predating firmware 2.8 carry 1-Wire temperatures in the deprecated repeated field, so those are lifted onto the

* per-channel fields first — see [withLegacyOneWireTemperatures].

*/

Tff7b72private Tff7b72fun Te6edf3EnvironmentMetricsTb4b4b4.Td2a8ffwithSentinelsForAbsentReadingsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3EnvironmentMetrics Tff7b72=

Te6edf3withLegacyOneWireTemperaturesTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3withScalarSentinelsTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3withChannelSentinelsTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72fun Te6edf3EnvironmentMetricsTb4b4b4.Td2a8ffwithScalarSentinelsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3EnvironmentMetrics Tff7b72= Te6edf3copyTb4b4b4(

Te6edf3temperature Tff7b72= Te6edf3temperature Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3relative_humidity Tff7b72= Te6edf3relative_humidity Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3soil_temperature Tff7b72= Te6edf3soil_temperature Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3barometric_pressure Tff7b72= Te6edf3barometric_pressure Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3gas_resistance Tff7b72= Te6edf3gas_resistance Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3voltage Tff7b72= Te6edf3voltage Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3current Tff7b72= Te6edf3current Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3lux Tff7b72= Te6edf3lux Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3uv_lux Tff7b72= Te6edf3uv_lux Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4,

Te6edf3iaq Tff7b72= Te6edf3iaq Tff7b72?: Tffa657IntTb4b4b4.Te6edf3MIN_VALUETb4b4b4,

Te6edf3soil_moisture Tff7b72= Te6edf3soil_moisture Tff7b72?: Tffa657IntTb4b4b4.Te6edf3MIN_VALUETb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72fun Te6edf3EnvironmentMetricsTb4b4b4.Td2a8ffwithChannelSentinelsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3EnvironmentMetrics Tff7b72=

Tb4b4b4(T79c0ff0 Te6edf3until Te6edf3TELEMETRY_CHANNEL_COUNTTb4b4b4)Tb4b4b4.Te6edf3foldTb4b4b4(Tff7b72thisTb4b4b4) Tb4b4b4{ Te6edf3metricsTb4b4b4, Te6edf3channel Tff7b72-Tff7b72>

Te6edf3metrics

Tb4b4b4.Te6edf3withOneWireTemperatureTb4b4b4(Te6edf3channelTb4b4b4, Te6edf3metricsTb4b4b4.Te6edf3oneWireTemperatureTb4b4b4(Te6edf3channelTb4b4b4) Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4)

Tb4b4b4.Te6edf3withAdcVoltageTb4b4b4(Te6edf3channelTb4b4b4, Te6edf3metricsTb4b4b4.Te6edf3adcVoltageTb4b4b4(Te6edf3channelTb4b4b4) Tff7b72?: Tffa657FloatTb4b4b4.Te6edf3NaNTb4b4b4)

Tb4b4b4}